#ifndef __APP_MQTT_H__
#define __APP_MQTT_H__
#include "app_common.h"

#define ADDRESS "ws://192.168.55.45:1883"
#define CLIENTID "f14bffa2-6dbf-4740-a482-c483a8941f15"
#define TOPIC_PULL "pull" // 订阅的主题
#define TOPIC_PUSH "push" // 发送消息的主题
#define QOS 1
#define TIMEOUT 10000L
/**
 * @brief 初始化mqtt客户端
 */
int app_mqtt_init(void);

/**
 * @brief 关闭mqtt客户端
 */
void app_mqtt_close(void);

/**
 * @brief 发送消息
 */
int app_mqtt_send(char *data, int len);

/**
 * @brief 注册处理消息数据的回调函数
 */
void app_mqtt_registerRecvCallBack(CallBack callback);

#endif
